package db

import "github.com/streadway/amqp"

var MQ *amqp.Connection

func MQInit() {
	conn, err := amqp.Dial("amqp://guest:guest@localhost:5672/")
	if err != nil {
		panic(err.Error())
	}
	MQ = conn
}
